from time import time
from job import celery_job
from utils.myredis import r

@celery_job.task()
def check_orders():
    #从list中获取订单号
    #通过支付宝查询接口查询
    #根据支付宝返回结果更新订单
    print("sdfsf")
    pass



# 清除大于半小时没有支付的订单
def cancle_orders():
    # 获取指定时间段过期
    end = int(time.time())
    orders = r.zset_byscore('cancleorders',0,end)
    # 遍历订单
    for i in orders:
        # 根据订单号对数据库操作
        sql = ""



